package com.cloud.point.concurrent.disruptor;

import com.lmax.disruptor.EventHandler;
import lombok.extern.slf4j.Slf4j;

/**
 * LongEventHandler
 *
 * @author 24373
 * @version 1.0
 * @date 2024-06-27 22:42
 */
@Slf4j
public class LongEventHandler2 implements EventHandler<LongEvent> {

    @Override
    public void onEvent(LongEvent event, long sequence, boolean endOfBatch) throws Exception {
        log.info("==消费者2:{},序号:{},batch:{}", event.getValue(), sequence, endOfBatch);
    }

}
